const eventPollingStarted = createAction('serverPolling/started')

listenerMiddleware.startListening({
  actionCreator: eventPollingStarted,
  effect: async (action, listenerApi) => {
    // Stop listening for this action
    listenerApi.unsubscribe()

    const pollingTask = listenerApi.fork(async (forkApi) => {
      try {
        // Cancellation-aware indefinite pause
        await forkApi.pause(new Promise(() => {}))
      } catch (err) {
        if (err instanceof TaskAbortError) {
          // Never runs
          console.log('pollingTask aborted')
        }
      }
    })

    try {
      // Wait indefinitely
      await listenerApi.condition(() => false)
      pollingTask.cancel()
    } catch (err) {
      if (err instanceof TaskAbortError) {
        // Never runs
        console.log('top-level task aborted')
      }
    }
  },
})

store.dispatch(eventPollingStarted())

// Some time later, while the tasks are still running, call clearListeners.
setTimeout(() => {
  listenerMiddleware.clearListeners()
}, 500);